package cn.doitedu.day04

import cn.doitedu.day01.utils.SparkUtil

/**
 * @Date 22.4.1
 * @Created by HANGGE
 * @Description
 */
object C15_转换算子_交集_并集_差集 {
  def main(args: Array[String]): Unit = {

    val sc = SparkUtil.getSc
    val rdd1 = sc.makeRDD(List(1, 2, 3, 4, 5, 6, 7, 8))
    val rdd2 = sc.makeRDD(List(6,6, 7, 8,9,10,11,12))
    //  两个RDD的交集   去重  在两个RDD中都出现的元素
    val res1 = rdd1.intersection(rdd2)
   // 在两个RDD中所有的元素  不会去重
    val res2 = rdd1.union(rdd2)
    // 在RDD1中出现在RDD2中没有出现的元素
    val res3 = rdd1.subtract(rdd2)
    res3.foreach(println)
  }

}
